1. 添加依赖 pom.xml如下: 2. Producer 的开发步骤 1. 实例化Producer Gr ...
1. 添加依赖 pom.xml如下: 2. Producer 的开发步骤 1. 实例化Producer Gr ...
1. PushConsumer 推,Broker主动向Consumer推消息,它Consumer的一种,应用通常向对象注册一个Listener接口,一旦接收到消息,Consumer对象立 ...
1. 修改RocketMQ默认启动端口 由于只有两台机器,部署双主双从需要四个节点,所以只能修改rocketmq的默认启动端口,从官网下载rocketmq的source文件,解压后使用i ...
1. 事务消息原理图 RocketMQ除了支持普通消息,顺序消息之外,还支持了事务消息。 1. 什么是分布式事务? 分布式事务就是指事务的参与者、支持事务的服务器、资源服务器以及事务管 ...
1. 下载rocketmq-console-ng 官网地址:https://github.com/apache/rocketmq-externals 拉下来之后,使用i ...